package com.burges.net.dataStream.windows.lateness

/**
  * 创建人    BurgessLee 
  * 创建时间   2020/2/3 
  * 描述
  */
object LatenessDemo {

	def main(args: Array[String]): Unit = {
//		val lateOutputTag = OutputTag[T]("late-data")
//		val input: DataStream[T] = ...
//		val result = input.keyBy(<key selector>).window(<window assigner>).allowedLateness(<time>)
//			//通过sideOutputLateData方法对迟到时数据进行标记
//			.sizeOutputLateData(lateOutputTag)
//			.process(...)

		//最后通过lateOutputTag从窗口数据中获取迟到的数据产生的统计结果
//		val lateStream = result.getSideOutput(lateOutputTag)
	}

}
